home *** CD-ROM | disk | FTP | other *** search
/ Aminet 1 (Walnut Creek) / Aminet - June 1993 [Walnut Creek].iso / usenet / sources / volume90 / unix / uucp103d / part07 < prev    next >
Internet Message Format  |  1990-02-04  |  55KB
  1. Path: xanth!cs.odu.edu!Amiga-Request
  2. From: Amiga-Request@cs.odu.edu (Amiga Sources/Binaries Moderator)
  3. Newsgroups: comp.sources.amiga
  4. Subject: v90i051: uucp 1.03D - unix compatible uucp/mail/news system, Part07/16
  5. Message-ID: <11290@xanth.cs.odu.edu>
  6. Date: 4 Feb 90 02:35:07 GMT
  7. Sender: tadguy@cs.odu.edu
  8. Reply-To: overload!dillon (Matt Dillon)
  9. Lines: 2009
  10. Approved: tadguy@cs.odu.edu (Tad Guy)
  11. X-Mail-Submissions-To: Amiga@cs.odu.edu
  12.  
  13. Submitted-by: overload!dillon (Matt Dillon)
  14. Posting-number: Volume 90, Issue 051
  15. Archive-name: unix/uucp-1.03d/part07
  16.  
  17. #!/bin/sh
  18. # This is a shell archive.  Remove anything before this line, then unpack
  19. # it by saving it into a file and typing "sh file".  To overwrite existing
  20. # files, type "sh file -c".  You can also feed this as standard input via
  21. # unshar, or by typing "sh <file", e.g..  If this archive is complete, you
  22. # will see the following message at the end:
  23. #        "End of archive 7 (of 16)."
  24. # Contents:  man/GNU-LICENSE src/dmail/execom.c src/uucico/sysdep.c
  25. #   src/uuser/uuser.c
  26. # Wrapped by tadguy@xanth on Sat Feb  3 20:51:12 1990
  27. PATH=/bin:/usr/bin:/usr/ucb ; export PATH
  28. if test -f 'man/GNU-LICENSE' -a "${1}" != "-c" ; then 
  29.   echo shar: Will not clobber existing file \"'man/GNU-LICENSE'\"
  30. else
  31. echo shar: Extracting \"'man/GNU-LICENSE'\" \(12488 characters\)
  32. sed "s/^X//" >'man/GNU-LICENSE' <<'END_OF_FILE'
  33. X
  34. X            GNU GENERAL PUBLIC LICENSE
  35. X             Version 1, February 1989
  36. X
  37. X Copyright (C) 1989 Free Software Foundation, Inc.
  38. X                    675 Mass Ave, Cambridge, MA 02139, USA
  39. X Everyone is permitted to copy and distribute verbatim copies
  40. X of this license document, but changing it is not allowed.
  41. X
  42. X                Preamble
  43. X
  44. X  The license agreements of most software companies try to keep users
  45. Xat the mercy of those companies.  By contrast, our General Public
  46. XLicense is intended to guarantee your freedom to share and change free
  47. Xsoftware--to make sure the software is free for all its users.  The
  48. XGeneral Public License applies to the Free Software Foundation's
  49. Xsoftware and to any other program whose authors commit to using it.
  50. XYou can use it for your programs, too.
  51. X
  52. X  When we speak of free software, we are referring to freedom, not
  53. Xprice.  Specifically, the General Public License is designed to make
  54. Xsure that you have the freedom to give away or sell copies of free
  55. Xsoftware, that you receive source code or can get it if you want it,
  56. Xthat you can change the software or use pieces of it in new free
  57. Xprograms; and that you know you can do these things.
  58. X
  59. X  To protect your rights, we need to make restrictions that forbid
  60. Xanyone to deny you these rights or to ask you to surrender the rights.
  61. XThese restrictions translate to certain responsibilities for you if you
  62. Xdistribute copies of the software, or if you modify it.
  63. X
  64. X  For example, if you distribute copies of a such a program, whether
  65. Xgratis or for a fee, you must give the recipients all the rights that
  66. Xyou have.  You must make sure that they, too, receive or can get the
  67. Xsource code.  And you must tell them their rights.
  68. X
  69. X  We protect your rights with two steps: (1) copyright the software, and
  70. X(2) offer you this license which gives you legal permission to copy,
  71. Xdistribute and/or modify the software.
  72. X
  73. X  Also, for each author's protection and ours, we want to make certain
  74. Xthat everyone understands that there is no warranty for this free
  75. Xsoftware.  If the software is modified by someone else and passed on, we
  76. Xwant its recipients to know that what they have is not the original, so
  77. Xthat any problems introduced by others will not reflect on the original
  78. Xauthors' reputations.
  79. X
  80. X  The precise terms and conditions for copying, distribution and
  81. Xmodification follow.
  82. X
  83. X            GNU GENERAL PUBLIC LICENSE
  84. X   TERMS AND CONDITIONS FOR COPYING, DISTRIBUTION AND MODIFICATION
  85. X
  86. X  0. This License Agreement applies to any program or other work which
  87. Xcontains a notice placed by the copyright holder saying it may be
  88. Xdistributed under the terms of this General Public License.  The
  89. X"Program", below, refers to any such program or work, and a "work based
  90. Xon the Program" means either the Program or any work containing the
  91. XProgram or a portion of it, either verbatim or with modifications.  Each
  92. Xlicensee is addressed as "you".
  93. X
  94. X  1. You may copy and distribute verbatim copies of the Program's source
  95. Xcode as you receive it, in any medium, provided that you conspicuously and
  96. Xappropriately publish on each copy an appropriate copyright notice and
  97. Xdisclaimer of warranty; keep intact all the notices that refer to this
  98. XGeneral Public License and to the absence of any warranty; and give any
  99. Xother recipients of the Program a copy of this General Public License
  100. Xalong with the Program.  You may charge a fee for the physical act of
  101. Xtransferring a copy.
  102. X
  103. X  2. You may modify your copy or copies of the Program or any portion of
  104. Xit, and copy and distribute such modifications under the terms of Paragraph
  105. X1 above, provided that you also do the following:
  106. X
  107. X    a) cause the modified files to carry prominent notices stating that
  108. X    you changed the files and the date of any change; and
  109. X
  110. X    b) cause the whole of any work that you distribute or publish, that
  111. X    in whole or in part contains the Program or any part thereof, either
  112. X    with or without modifications, to be licensed at no charge to all
  113. X    third parties under the terms of this General Public License (except
  114. X    that you may choose to grant warranty protection to some or all
  115. X    third parties, at your option).
  116. X
  117. X    c) If the modified program normally reads commands interactively when
  118. X    run, you must cause it, when started running for such interactive use
  119. X    in the simplest and most usual way, to print or display an
  120. X    announcement including an appropriate copyright notice and a notice
  121. X    that there is no warranty (or else, saying that you provide a
  122. X    warranty) and that users may redistribute the program under these
  123. X    conditions, and telling the user how to view a copy of this General
  124. X    Public License.
  125. X
  126. X    d) You may charge a fee for the physical act of transferring a
  127. X    copy, and you may at your option offer warranty protection in
  128. X    exchange for a fee.
  129. X
  130. XMere aggregation of another independent work with the Program (or its
  131. Xderivative) on a volume of a storage or distribution medium does not bring
  132. Xthe other work under the scope of these terms.
  133. X
  134. X  3. You may copy and distribute the Program (or a portion or derivative of
  135. Xit, under Paragraph 2) in object code or executable form under the terms of
  136. XParagraphs 1 and 2 above provided that you also do one of the following:
  137. X
  138. X    a) accompany it with the complete corresponding machine-readable
  139. X    source code, which must be distributed under the terms of
  140. X    Paragraphs 1 and 2 above; or,
  141. X
  142. X    b) accompany it with a written offer, valid for at least three
  143. X    years, to give any third party free (except for a nominal charge
  144. X    for the cost of distribution) a complete machine-readable copy of the
  145. X    corresponding source code, to be distributed under the terms of
  146. X    Paragraphs 1 and 2 above; or,
  147. X
  148. X    c) accompany it with the information you received as to where the
  149. X    corresponding source code may be obtained.  (This alternative is
  150. X    allowed only for noncommercial distribution and only if you
  151. X    received the program in object code or executable form alone.)
  152. X
  153. XSource code for a work means the preferred form of the work for making
  154. Xmodifications to it.  For an executable file, complete source code means
  155. Xall the source code for all modules it contains; but, as a special
  156. Xexception, it need not include source code for modules which are standard
  157. Xlibraries that accompany the operating system on which the executable
  158. Xfile runs, or for standard header files or definitions files that
  159. Xaccompany that operating system.
  160. X
  161. X  4. You may not copy, modify, sublicense, distribute or transfer the
  162. XProgram except as expressly provided under this General Public License.
  163. XAny attempt otherwise to copy, modify, sublicense, distribute or transfer
  164. Xthe Program is void, and will automatically terminate your rights to use
  165. Xthe Program under this License.  However, parties who have received
  166. Xcopies, or rights to use copies, from you under this General Public
  167. XLicense will not have their licenses terminated so long as such parties
  168. Xremain in full compliance.
  169. X
  170. X  5. By copying, distributing or modifying the Program (or any work based
  171. Xon the Program) you indicate your acceptance of this license to do so,
  172. Xand all its terms and conditions.
  173. X
  174. X  6. Each time you redistribute the Program (or any work based on the
  175. XProgram), the recipient automatically receives a license from the original
  176. Xlicensor to copy, distribute or modify the Program subject to these
  177. Xterms and conditions.  You may not impose any further restrictions on the
  178. Xrecipients' exercise of the rights granted herein.
  179. X
  180. X  7. The Free Software Foundation may publish revised and/or new versions
  181. Xof the General Public License from time to time.  Such new versions will
  182. Xbe similar in spirit to the present version, but may differ in detail to
  183. Xaddress new problems or concerns.
  184. X
  185. XEach version is given a distinguishing version number.  If the Program
  186. Xspecifies a version number of the license which applies to it and "any
  187. Xlater version", you have the option of following the terms and conditions
  188. Xeither of that version or of any later version published by the Free
  189. XSoftware Foundation.  If the Program does not specify a version number of
  190. Xthe license, you may choose any version ever published by the Free Software
  191. XFoundation.
  192. X
  193. X  8. If you wish to incorporate parts of the Program into other free
  194. Xprograms whose distribution conditions are different, write to the author
  195. Xto ask for permission.  For software which is copyrighted by the Free
  196. XSoftware Foundation, write to the Free Software Foundation; we sometimes
  197. Xmake exceptions for this.  Our decision will be guided by the two goals
  198. Xof preserving the free status of all derivatives of our free software and
  199. Xof promoting the sharing and reuse of software generally.
  200. X
  201. X                NO WARRANTY
  202. X
  203. X  9. BECAUSE THE PROGRAM IS LICENSED FREE OF CHARGE, THERE IS NO WARRANTY
  204. XFOR THE PROGRAM, TO THE EXTENT PERMITTED BY APPLICABLE LAW.  EXCEPT WHEN
  205. XOTHERWISE STATED IN WRITING THE COPYRIGHT HOLDERS AND/OR OTHER PARTIES
  206. XPROVIDE THE PROGRAM "AS IS" WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED
  207. XOR IMPLIED, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
  208. XMERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.  THE ENTIRE RISK AS
  209. XTO THE QUALITY AND PERFORMANCE OF THE PROGRAM IS WITH YOU.  SHOULD THE
  210. XPROGRAM PROVE DEFECTIVE, YOU ASSUME THE COST OF ALL NECESSARY SERVICING,
  211. XREPAIR OR CORRECTION.
  212. X
  213. X  10. IN NO EVENT UNLESS REQUIRED BY APPLICABLE LAW OR AGREED TO IN WRITING
  214. XWILL ANY COPYRIGHT HOLDER, OR ANY OTHER PARTY WHO MAY MODIFY AND/OR
  215. XREDISTRIBUTE THE PROGRAM AS PERMITTED ABOVE, BE LIABLE TO YOU FOR DAMAGES,
  216. XINCLUDING ANY GENERAL, SPECIAL, INCIDENTAL OR CONSEQUENTIAL DAMAGES ARISING
  217. XOUT OF THE USE OR INABILITY TO USE THE PROGRAM (INCLUDING BUT NOT LIMITED
  218. XTO LOSS OF DATA OR DATA BEING RENDERED INACCURATE OR LOSSES SUSTAINED BY
  219. XYOU OR THIRD PARTIES OR A FAILURE OF THE PROGRAM TO OPERATE WITH ANY OTHER
  220. XPROGRAMS), EVEN IF SUCH HOLDER OR OTHER PARTY HAS BEEN ADVISED OF THE
  221. XPOSSIBILITY OF SUCH DAMAGES.
  222. X
  223. X             END OF TERMS AND CONDITIONS
  224. X
  225. X    Appendix: How to Apply These Terms to Your New Programs
  226. X
  227. X  If you develop a new program, and you want it to be of the greatest
  228. Xpossible use to humanity, the best way to achieve this is to make it
  229. Xfree software which everyone can redistribute and change under these
  230. Xterms.
  231. X
  232. X  To do so, attach the following notices to the program.  It is safest to
  233. Xattach them to the start of each source file to most effectively convey
  234. Xthe exclusion of warranty; and each file should have at least the
  235. X"copyright" line and a pointer to where the full notice is found.
  236. X
  237. X    <one line to give the program's name and a brief idea of what it does.>
  238. X    Copyright (C) 19yy  <name of author>
  239. X
  240. X    This program is free software; you can redistribute it and/or modify
  241. X    it under the terms of the GNU General Public License as published by
  242. X    the Free Software Foundation; either version 1, or (at your option)
  243. X    any later version.
  244. X
  245. X    This program is distributed in the hope that it will be useful,
  246. X    but WITHOUT ANY WARRANTY; without even the implied warranty of
  247. X    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  248. X    GNU General Public License for more details.
  249. X
  250. X    You should have received a copy of the GNU General Public License
  251. X    along with this program; if not, write to the Free Software
  252. X    Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  253. X
  254. XAlso add information on how to contact you by electronic and paper mail.
  255. X
  256. XIf the program is interactive, make it output a short notice like this
  257. Xwhen it starts in an interactive mode:
  258. X
  259. X    Gnomovision version 69, Copyright (C) 19xx name of author
  260. X    Gnomovision comes with ABSOLUTELY NO WARRANTY; for details type `show w'.
  261. X    This is free software, and you are welcome to redistribute it
  262. X    under certain conditions; type `show c' for details.
  263. X
  264. XThe hypothetical commands `show w' and `show c' should show the
  265. Xappropriate parts of the General Public License.  Of course, the
  266. Xcommands you use may be called something other than `show w' and `show
  267. Xc'; they could even be mouse-clicks or menu items--whatever suits your
  268. Xprogram.
  269. X
  270. XYou should also get your employer (if you work as a programmer) or your
  271. Xschool, if any, to sign a "copyright disclaimer" for the program, if
  272. Xnecessary.  Here a sample; alter the names:
  273. X
  274. X  Yoyodyne, Inc., hereby disclaims all copyright interest in the
  275. X  program `Gnomovision' (a program to direct compilers to make passes
  276. X  at assemblers) written by James Hacker.
  277. X
  278. X  <signature of Ty Coon>, 1 April 1989
  279. X  Ty Coon, President of Vice
  280. X
  281. XThat's all there is to it!
  282. END_OF_FILE
  283. if test 12488 -ne `wc -c <'man/GNU-LICENSE'`; then
  284.     echo shar: \"'man/GNU-LICENSE'\" unpacked with wrong size!
  285. fi
  286. # end of 'man/GNU-LICENSE'
  287. fi
  288. if test -f 'src/dmail/execom.c' -a "${1}" != "-c" ; then 
  289.   echo shar: Will not clobber existing file \"'src/dmail/execom.c'\"
  290. else
  291. echo shar: Extracting \"'src/dmail/execom.c'\" \(12732 characters\)
  292. sed "s/^X//" >'src/dmail/execom.c' <<'END_OF_FILE'
  293. X
  294. X/*
  295. X *  EXECOM.C
  296. X *
  297. X *  (C) Copyright 1985-1990 by Matthew Dillon,  All Rights Reserved.
  298. X *
  299. X *  Routines to parse and execute command lines.
  300. X *
  301. X *  Global Routines:    DO_COMMAND()
  302. X *            EXEC_COMMAND()
  303. X *            FIX()
  304. X *
  305. X *  Static Routines:    E_COMMAND()
  306. X *            BREAKOUT()
  307. X *            FIND_COMMAND()
  308. X */
  309. X
  310. X
  311. X#include <pwd.h>
  312. X#include <stdio.h>
  313. X#include <string.h>
  314. X#include "dmail.h"
  315. X#include "execom.h"
  316. X
  317. X#define F_EXACT     0
  318. X#define F_ABBR        1
  319. X#define SCRBUF        1024
  320. X
  321. Xextern char *breakout();
  322. X
  323. Xextern int do_quit(), do_exit(), do_help(), do_list(), do_setlist();
  324. Xextern int do_select(), do_type(), do_header(), do_next(), do_mark();
  325. Xextern int do_unmark(), do_reply(), do_delnext(), do_rlist();
  326. Xextern int do_write(), do_shell(), do_set_var(), do_unset_var();
  327. Xextern int do_number(), do_cd(), do_source(), do_defer(), do_echo();
  328. Xextern int do_go(), do_break();
  329. X
  330. Xextern int do_if(), do_else(), do_endif();
  331. Xextern int do_ver(), do_delprev();
  332. X
  333. Xstruct COMMAND Command[] = {
  334. X    do_number   , 0,    0,            "",
  335. X    do_mark     , 0,    ST_DELETED,        "delete",
  336. X    do_unmark   , 0,    ST_DELETED,        "undelete",
  337. X    do_header   , 0,    0,            "header",
  338. X    do_type     , 0,    0,            "type",
  339. X    do_echo     , 0,    0,            "echo",
  340. X    do_go        , 0,    0,            "go",
  341. X    do_reply    , 0,    R_REPLY,        "reply",
  342. X    do_reply    , 0,    R_INCLUDE,        "Reply",
  343. X    do_reply    , 0,    R_MAIL,         "mail",
  344. X    do_reply    , 0,    R_FORWARD,        "forward",
  345. X    do_select   , 0,    0,            "select",
  346. X    do_select   , 0,    1,            "reselect",
  347. X    do_defer    , 0,    1,            "defer",
  348. X    do_list     , 0,    0,            "list",
  349. X    do_rlist    , 0,    0,            "rlist",
  350. X    do_next     , 0,    1,            "next",
  351. X    do_next     , 0,    -1,            "back",
  352. X    do_next     , 0,    2,            "_next",
  353. X    do_next     , 0,    -2,            "_back",
  354. X    do_delnext  , 0,    0,            "dt",
  355. X    do_delprev  , 0,    0,            "db",
  356. X    do_set_var  , 0,    0,            "set",
  357. X    do_unset_var, 0,    0,            "unset",
  358. X    do_set_var  , 0,    1,            "alias",
  359. X    do_unset_var, 0,    1,            "unalias",
  360. X    do_set_var  , C_NO,    2,            "malias",
  361. X    do_unset_var, C_NO,    2,            "munalias",
  362. X    do_setlist  , 0,    0,            "setlist",
  363. X    do_cd        , 0,    0,            "cd",
  364. X    do_source   , 0,    0,            "source",
  365. X    do_unmark   , 0,    ST_READ | ST_STORED,"preserve",
  366. X    do_mark     , 0,    ST_READ,        "mark",
  367. X    do_mark     , 0,    ST_TAG,         "tag",
  368. X    do_unmark   , 0,    ST_TAG,         "untag",
  369. X    do_unmark   , 0,    ST_STORED,        "unwrite",
  370. X    do_write    , 0,    0,            "write",
  371. X    do_shell    , 0,    0,            "!",
  372. X    do_exit     , 0,    0,            "x",
  373. X    do_quit     , 0,    0,            "quit",
  374. X    do_exit     , 0,    1,            "xswitch",
  375. X    do_quit     , 0,    1,            "qswitch",
  376. X    do_help     , 0,    0,            "help",
  377. X    do_help     , 0,    0,            "?",
  378. X    do_break    , 0,    0,            "nobreak",
  379. X    do_break    , 0,    1,            "breakok",
  380. X    do_if        , C_COND,    0,            "if",
  381. X    do_else     , C_COND,    0,            "else",
  382. X    do_endif    , C_COND,    0,            "endif",
  383. X    do_ver        , 0,    0,            "version",
  384. X    NULL        , 0,    0,            NULL };
  385. X
  386. Xchar *Desc[] = {
  387. X    "",
  388. X    "<list>                   mark messages for deletion",
  389. X    "<list>                   UNDELETE & UNMARK messages",
  390. X    "[msg]                    Display header of a message",
  391. X    "[msg]                    type a message",
  392. X    "args....                 Echo to the screen",
  393. X    "#                        Go to a message, don't print out",
  394. X    "                         reply to mail",
  395. X    "                         reply to mail, include recv'd text",
  396. X    "user user ...            send mail to users",
  397. X    "user user ...            forward mail to users",
  398. X    "Field [!]match [match][ , Field match.]  SELECT from entire message list",
  399. X    "Field [!]match [match][ , Field match.]  SELECT from current message list",
  400. X    "                         De-select any read messages",
  401. X    "<list>                   list mail as specified by SETLIST",
  402. X    "[+/-][N]                 list relative to current position",
  403. X    "[msg]                    type/header next or message #",
  404. X    "[msg]                    type/header previous or message #",
  405. X    "[msg]                    go to next or message #",
  406. X    "[msg]                    go to previous or message #",
  407. X    "                         delete current, type next",
  408. X    "                         delete current, type prev",
  409. X    "[var [string]]           set a variable",
  410. X    "var var var ...          unset a variable",
  411. X    "[var [string]]           set an alias",
  412. X    "var var var ...          unset an alias",
  413. X    "[var [string]]           set a mail alias",
  414. X    "var var var ...          unset a mail alias",
  415. X    "[-s] [cols] Field [cols] Field...    SET LIST format for LIST",
  416. X    "path                     CD to a directory",
  417. X    "file                     Source a file",
  418. X    "<list>                   UNREAD & UNMARK messages",
  419. X    "<list>                   mark messages as 'read'",
  420. X    "<list>                   tag messages for whatever",
  421. X    "<list>                   untag messages",
  422. X    "<list>                   unwrite messages",
  423. X    "file <list>              append messages to a file, delete on quit",
  424. X    "[command]                execute a shell [command]",
  425. X    "                         EXIT, do not save changes",
  426. X    "                         QUIT, update files",
  427. X    "from to                  Exit and switch to a new from/to file",
  428. X    "from to                  Quit and switch to a new from/to file",
  429. X    "[topic]                  help on a topic",
  430. X    "[topic]                  alternate form of HELP",
  431. X    "                         Disable INTR (stackable)",
  432. X    "                         Enable  INTR (stackable)",
  433. X    "[!]variable              conditionals (stackable)",
  434. X    "",
  435. X    "",
  436. X    "                         Print the version number",
  437. X    NULL };
  438. X
  439. X
  440. Xdo_command()
  441. X{
  442. X    static char comline[1024];
  443. X
  444. X    if (Current >= 0 && Current < Entries)
  445. X    printf("%3d:", Entry[Current].no);
  446. X    else
  447. X    printf("nul:");
  448. X    fflush (stdout);
  449. X    if (gets (comline) == NULL)
  450. X    done (1);
  451. X    exec_command(comline);
  452. X    return (1);
  453. X}
  454. X
  455. X
  456. X
  457. X/*
  458. X * EXEC_COMMAND()
  459. X *
  460. X *
  461. X */
  462. X
  463. X
  464. Xstruct MLIST {
  465. X    struct MLIST *next;
  466. X};
  467. X
  468. Xstatic struct MLIST *Mlist;
  469. X
  470. Xchar *
  471. Xmpush(amount)
  472. Xint amount;
  473. X{
  474. X    struct MLIST *ml;
  475. X
  476. X    push_break();
  477. X    ml = (struct MLIST *)malloc (amount + sizeof(*Mlist));
  478. X    ml->next = Mlist;
  479. X    Mlist = ml;
  480. X    pop_break();
  481. X    return ((char *)Mlist + sizeof(*Mlist));
  482. X}
  483. X
  484. X
  485. Xchar *
  486. Xmpop()
  487. X{
  488. X    char *old = NULL;
  489. X
  490. X    push_break();
  491. X    if (Mlist == NULL) {
  492. X    puts ("MLIST INTERNAL ERROR");
  493. X    } else {
  494. X    old = (char *)Mlist + sizeof(*Mlist);
  495. X    xfree (Mlist);
  496. X    Mlist = Mlist->next;
  497. X    }
  498. X    pop_break();
  499. X    return (old);
  500. X}
  501. X
  502. Xvoid
  503. Xmrm()
  504. X{
  505. X    push_break();
  506. X    while (Mlist) {
  507. X    xfree (Mlist);
  508. X    Mlist = Mlist->next;
  509. X    }
  510. X    pop_break();
  511. X}
  512. X
  513. X
  514. Xexec_command(base)
  515. Xchar *base;
  516. X{
  517. X    char *str;
  518. X    int i;
  519. X
  520. X    if (push_base()) {
  521. X    push_break();
  522. X    pop_base();
  523. X    mrm();
  524. X    pop_break();
  525. X    return (-1);
  526. X    }
  527. X    strcpy (str = mpush(strlen(base) + 1), base);
  528. X    i = e_command(str);
  529. X    if (mpop() != str)
  530. X    puts ("POP ERROR");
  531. X    pop_base();
  532. X    return (i);
  533. X}
  534. X
  535. X
  536. Xstatic
  537. Xe_command(base)
  538. Xchar *base;
  539. X{
  540. X    char *com, *start, *avline, *alias;
  541. X    int flag = 0;
  542. X    int i, pcount, len, ccno;
  543. X
  544. Xloop:
  545. X    com = breakout (&base, &flag);
  546. X    if (*com == '\0') {
  547. X    if (flag > 1)
  548. X        return (1);
  549. X    goto loop;
  550. X    }
  551. X    if ((ccno = find_command(com, F_EXACT)) < 0) {
  552. X    if (*com == '$')
  553. X        alias = get_var (LEVEL_SET, com + 1);
  554. X    else
  555. X        alias = get_var (LEVEL_ALIAS, com);
  556. X    if (alias == NULL) {
  557. X        if ((ccno = find_command (com, F_ABBR)) < 0) {
  558. X        if (!XDisable)
  559. X            printf ("%s Command Not found\n", com);
  560. X        return (XDisable ? 1 : -1);
  561. X        } else {
  562. X        goto good_command;
  563. X        }
  564. X    }
  565. X
  566. X    /* At this point, base points to arguments */
  567. X
  568. X    start = (flag == 0) ? base : "";
  569. X    while (flag == 0) {             /* find ';' or end of string        */
  570. X        flag = -1;            /* disable breakout's "" terminator */
  571. X        breakout (&base, &flag);
  572. X    }
  573. X
  574. X    /*
  575. X     * At this point, start points to all arguments, base set up for next
  576. X     * string
  577. X     */
  578. X
  579. X    if (*alias == '%') {
  580. X        int xx = 0;
  581. X        char *select;
  582. X
  583. X        alias = strcpy (mpush (strlen(alias) + 1), alias);
  584. X        select = breakout (&alias, &xx);
  585. X        set_var (LEVEL_SET, select + 1, start);
  586. X        i = e_command (alias);
  587. X        unset_var (LEVEL_SET, select + 1);
  588. X        mpop();
  589. X    } else {
  590. X        com = mpush (strlen(alias) + strlen(start) + 2);
  591. X        strcpy (com, alias);
  592. X        strcat (com, (flag == 1) ? ";" : " ");
  593. X        strcat (com, start);
  594. X        i = e_command (com);
  595. X        if (mpop() != com)
  596. X        puts ("ME BAE ERROR");
  597. X    }
  598. X    if (i < 0)
  599. X        return (-1);
  600. X    if (flag > 1)
  601. X        return (1);
  602. X    goto loop;
  603. X    }
  604. Xgood_command:
  605. X    if (XDisable && (Command[ccno].stat & C_COND) == 0) {
  606. X    while (flag < 1)
  607. X        breakout (&base, &flag);
  608. X    if (flag > 1)
  609. X        return (1);
  610. X    goto loop;
  611. X    }
  612. X    if (Command[ccno].stat & C_NO  &&  XDebug == 0) {
  613. X    printf ("%s  Is currently being developed\n", Command[ccno].name);
  614. X    return (-1);
  615. X    }
  616. X    if (XDebug)
  617. X    printf ("Good command, Raw: %s\n", com);
  618. X    i = pcount = 0;
  619. X    av[i] = mpush (strlen(com) + 1);
  620. X    ++pcount;
  621. X    strcpy (av[i++], com);
  622. X    while (flag < 1) {
  623. X    com = breakout (&base, &flag);
  624. X    if (XDebug)
  625. X        printf ("BREAKOUT %d %s\n", strlen(com), com);
  626. X    if (*com == '\0')
  627. X        continue;
  628. X    switch (*com) {
  629. X    case '~':
  630. X        if (com[1] == '/'  ||  com[1] == '\0') {
  631. X        av[i] = mpush (strlen(home_dir) + strlen(com + 1) + 1);
  632. X        ++pcount;
  633. X        strcpy (av[i], home_dir);
  634. X        strcat (av[i], com + 1);
  635. X        } else {
  636. X        struct passwd *passwd;
  637. X        char *user = com;
  638. X
  639. X        while (*com) {
  640. X            if (*com == '/') {
  641. X            *com = '\0';
  642. X            ++com;
  643. X            break;
  644. X            }
  645. X            ++com;
  646. X        }
  647. X        if ((passwd = getpwnam(user)) == NULL) {
  648. X            printf ("USER %s Not found\n", user);
  649. X            while (pcount--)
  650. X            mpop();
  651. X            return (-1);
  652. X        }
  653. X        av[i] = mpush (strlen(passwd->pw_dir) + strlen(com) + 2);
  654. X        ++pcount;
  655. X        strcpy (av[i], passwd->pw_dir);
  656. X        if (*com) {
  657. X            strcat (av[i], "/");
  658. X            strcat (av[i], com);
  659. X        }
  660. X        }
  661. X        break;
  662. X    case '\"':
  663. X        av[i] = com + 1;
  664. X        while (*++com && *com != '\"');
  665. X        *com = '\0';
  666. X        break;
  667. X    case '$':
  668. X        if (*(com + 1) == '$') {
  669. X        av[i] = getenv(com + 2);
  670. X        if (av[i] == NULL) {
  671. X            printf ("Env. Var %s not found\n", com + 2);
  672. X            av[i] = com;
  673. X        }
  674. X#ifdef AMIGA
  675. X        av[i] = strcpy (mpush(strlen(av[i]) + 1), av[i]);
  676. X        ++pcount;
  677. X#endif
  678. X        }  else {
  679. X        av[i] = get_var (LEVEL_SET, com + 1);
  680. X        if (av[i] == NULL)
  681. X            av[i] = com;
  682. X        av[i] = strcpy (mpush(strlen(av[i]) + 1), av[i]);
  683. X        ++pcount;
  684. X        }
  685. X        break;
  686. X    default:
  687. X        av[i] = com;
  688. X        break;
  689. X    }
  690. X    ++i;
  691. X    }
  692. X    av[i] = NULL;
  693. X    ac = i;
  694. X    for (len = 0, i = 0; i < ac; ++i)
  695. X    len += strlen (av[i]) + 1;
  696. X    avline = mpush (len + 1);
  697. X    *avline = '\0';
  698. X    for (i = 0; i < ac; ++i) {
  699. X    strcat (avline, av[i]);
  700. X    if (i + 1 < ac)
  701. X        strcat (avline, " ");
  702. X    }
  703. X    if (XDebug)
  704. X    printf ("DEST: %s\n", avline);
  705. X    i = (*Command[ccno].func)(avline, Command[ccno].val);
  706. X    if (mpop() != avline)
  707. X    puts ("AVLINE ERROR");
  708. X    while (pcount--)
  709. X    mpop();
  710. X    fix();
  711. X    if (i < 0)
  712. X    return (i);
  713. X    if (flag < 2)
  714. X    goto loop;
  715. X    return (1);
  716. X}
  717. X
  718. X
  719. X/*
  720. X * BREAKOUT
  721. X *
  722. X * Breakout next argument.  If FLAG is set to 1 on return, the argument
  723. X * returned is the last in the command.  If FLAG is set to 2 on return, the
  724. X * argument returned is the last, period.
  725. X *
  726. X */
  727. X
  728. Xstatic char *
  729. Xbreakout(base, flag)
  730. Xint *flag;
  731. Xchar **base;
  732. X{
  733. X    register char *str, *scr;
  734. X
  735. Xloop:
  736. X    str = *base;            /* next start        */
  737. X    while (*str == ' ' || *str == 9)    /* skip spaces and such */
  738. X    ++str;
  739. X    switch (*str) {
  740. X    case '\0':                          /* no more arguments    */
  741. X    *flag = 2;
  742. X    *base = str;
  743. X    return (str);
  744. X    case ';':                           /* no more args in this command */
  745. X    *flag = 1;
  746. X    *str = '\0';
  747. X    *base = str + 1;
  748. X    return (str);
  749. X    }
  750. X    scr = str;
  751. X    for (;;) {                          /* valid argument of somesort   */
  752. X    switch (*scr) {
  753. X    case ' ':
  754. X    case 9:
  755. X        if (*flag >= 0)
  756. X        *scr = '\0';
  757. X        *base = scr + 1;
  758. X        *flag = 0;
  759. X        return (str);
  760. X    case '\"':
  761. X        ++scr;
  762. X        while (*scr && (*scr++ != '\"'));   /* place to end of quote */
  763. X        break;
  764. X    case '\0':
  765. X        *flag = 2;
  766. X        *base = scr;
  767. X        return (str);
  768. X    case ';':
  769. X        *flag = 1;
  770. X        *base = scr + 1;
  771. X        *scr = '\0';
  772. X        return (str);
  773. X    default:
  774. X        ++scr;
  775. X    }
  776. X    }
  777. X}
  778. X
  779. X
  780. X
  781. Xfix()
  782. X{
  783. X    register int i;
  784. X
  785. X    for (i = (Current < 0) ? 0 : Current; i < Entries; ++i) {
  786. X    if (Entry[i].no  &&  !(Entry[i].status & ST_DELETED)) {
  787. X        Current = i;
  788. X        return (1);
  789. X    }
  790. X    }
  791. X    if (Current >= Entries) {
  792. X    Current = Entries - 1;
  793. X    /* Can become -1 if no entries  */
  794. X    }
  795. X    for (i = Current; i >= 0; --i) {
  796. X    if (Entry[i].no  &&  !(Entry[i].status & ST_DELETED)) {
  797. X        Current = i;
  798. X        return (-1);
  799. X    }
  800. X    }
  801. X    Current = -1;
  802. X    return (-1);
  803. X}
  804. X
  805. X
  806. Xstatic
  807. Xfind_command(str, arg)
  808. Xchar *str;
  809. Xint arg;
  810. X{
  811. X    int i;
  812. X    int len = strlen (str);
  813. X
  814. X    if (*str >= '0'  &&  *str <= '9')
  815. X    return (0);
  816. X    for (i = 0; Command[i].func; ++i) {
  817. X    if (strncmp (str, Command[i].name, len) == 0) {
  818. X        if (arg == F_ABBR)
  819. X        return (i);
  820. X        if (strcmp (str, Command[i].name) == 0)
  821. X        return (i);
  822. X        return (-1);
  823. X    }
  824. X    }
  825. X    return (-1);
  826. X}
  827. X
  828. END_OF_FILE
  829. if test 12732 -ne `wc -c <'src/dmail/execom.c'`; then
  830.     echo shar: \"'src/dmail/execom.c'\" unpacked with wrong size!
  831. fi
  832. # end of 'src/dmail/execom.c'
  833. fi
  834. if test -f 'src/uucico/sysdep.c' -a "${1}" != "-c" ; then 
  835.   echo shar: Will not clobber existing file \"'src/uucico/sysdep.c'\"
  836. else
  837. echo shar: Extracting \"'src/uucico/sysdep.c'\" \(11298 characters\)
  838. sed "s/^X//" >'src/uucico/sysdep.c' <<'END_OF_FILE'
  839. X
  840. X/*
  841. X * @(#)sysdep.amiga        Version Amiga 0.1     87/09/20
  842. X *
  843. X * (C) Copyright 1987 by John Gilmore
  844. X * Copying and use of this program are controlled by the terms of the Free
  845. X * Software Foundation's GNU Emacs General Public License.
  846. X *
  847. X *  Amiga Changes Copyright 1988 by William Loftus. All rights reserved.
  848. X *  Additional chgs Copyright 1989 by Matthew Dillon, All Rights Reserved.
  849. X */
  850. X
  851. X#include "/version.h"
  852. X
  853. Xstatic char *Version = "@(#)sysdep.amiga gnuucp" VERSION ".01";
  854. X
  855. X/*
  856. X *  Split out of uuslave.c by John Gilmore, 8 August 1987.
  857. X *  ported to the Amiga by William Loftus, 20 September 1987.
  858. X *  rewritten by Matthew Dillon, October 1989
  859. X */
  860. X
  861. X/* FIXME -- System dependent defines (not really -- should be in a .h) */
  862. X/*
  863. X * Timeout for raw characters -- if we don't hear a char within BYTE_TIMEOUT
  864. X * seconds, we assume the other side has gone away.  Has nothing to do with
  865. X * retransmission timeouts (if any!).
  866. X */
  867. Xextern int debug;
  868. X
  869. X/* Amiga */
  870. X#include "uucp.h"
  871. X#include "modem.h"
  872. X#include <exec/types.h>
  873. X#include <ctype.h>
  874. X#include <fcntl.h>
  875. X#include <exec/exec.h>
  876. X#include <exec/devices.h>
  877. X#include <devices/serial.h>
  878. X#include <devices/keymap.h>
  879. X#include <devices/timer.h>
  880. X#include <hardware/cia.h>
  881. X#include <libraries/dos.h>
  882. X#include <signal.h>
  883. X#include <stdio.h>
  884. X#include <stdlib.h>
  885. X#include <pwd.h>
  886. X#include <proto/exec.h>
  887. X
  888. X#define NAMESIZE 128
  889. X#define FAILURE  1
  890. X
  891. Xvoid printc();
  892. X
  893. Xextern struct MsgPort *CreatePort();
  894. Xstruct IOExtSer Iosr;
  895. Xstruct IOExtSer Iosw;
  896. Xstruct IOExtSer Ioss;
  897. Xstruct timerequest Iot0;
  898. Xchar   *OldTaskName;
  899. X
  900. Xchar    *DeviceName = "serial.device";
  901. Xlong    DeviceUnit = 0;
  902. X
  903. Xunsigned char    XInBuf[256];       /*  for xgetc() */
  904. Xshort    XInIdx = 0;
  905. Xshort    XInLen = 0;
  906. Xshort    IoswIP = 0;
  907. X
  908. Xshort    InExitRoutine = 0;
  909. Xshort    debugRead = 0;
  910. X
  911. Xextern char path[];
  912. Xextern int Getty;
  913. Xextern int IgnoreCD;
  914. X
  915. Xvoid set_baud();
  916. Xvoid OpenSerial();
  917. Xvoid CloseSerial();
  918. Xvoid xexit();
  919. X
  920. XCXBRK()
  921. X{
  922. X    return(0);
  923. X}
  924. X
  925. Xint
  926. Xopenout(acu, baud)
  927. Xchar *acu;
  928. Xint  baud;
  929. X{
  930. X    set_baud(baud);
  931. X
  932. X    return SUCCESS;
  933. X}
  934. X
  935. X/*
  936. X * Basement level I/O routines
  937. X *
  938. X * xwrite() writes a character string to the serial port
  939. X * xgetc() returns a character from the serial port, or an EOF for timeout.
  940. X * sigint() restores the state of the serial port on exit.
  941. X */
  942. X
  943. Xint
  944. Xsigint()
  945. X{
  946. X    xexit(1);
  947. X    return(0);
  948. X}
  949. X
  950. X
  951. Xvoid
  952. Xcleanup()
  953. X{
  954. X    xexit(0);
  955. X}
  956. X
  957. Xint
  958. Xxdatardy()
  959. X{
  960. X    if (XInIdx != XInLen)
  961. X    return(1);
  962. X    CheckCarrier();
  963. X    return (Ioss.IOSer.io_Actual > 0);
  964. X}
  965. X
  966. Xint
  967. Xxgetc(byteto)
  968. X{
  969. X    int ch, n;
  970. X    long smask;
  971. X    long tmask;
  972. X    short bytetimeout;
  973. X
  974. Xtop:
  975. X    if (XInIdx != XInLen) {
  976. X    if (debug > 8) {
  977. X        if (debugRead == 0)
  978. X        printf("\nREAD: ");
  979. X        debugRead = 1;
  980. X        printc(XInBuf[XInIdx]);
  981. X    }
  982. X    return((int)XInBuf[XInIdx++]);
  983. X    }
  984. X    XInIdx = 0;
  985. X    XInLen = 0;
  986. X
  987. X    if (!CheckCarrier())                        /*  carrier lost?     */
  988. X    return(EOF);
  989. X
  990. X    if ((n = Ioss.IOSer.io_Actual) > 0) {       /*  at least one..    */
  991. X    Iosr.IOSer.io_Command = CMD_READ;
  992. X    Iosr.IOSer.io_Data = (APTR)XInBuf;
  993. X    if (n > sizeof(XInBuf))
  994. X        n = sizeof(XInBuf);
  995. X    Iosr.IOSer.io_Length = n;
  996. X    DoIO(&Iosr);
  997. X    if (Iosr.IOSer.io_Actual > 0) {
  998. X        if (debug > 8)
  999. X        printf("(r%d/%d)", n, Iosr.IOSer.io_Actual);
  1000. X        XInIdx = 0;
  1001. X        XInLen = Iosr.IOSer.io_Actual;
  1002. X        goto top;
  1003. X    }
  1004. X    }
  1005. X
  1006. X    /*
  1007. X     *    no bytes ready, wait for one.
  1008. X     *
  1009. X     *    once every 3 seconds check carrier detect.
  1010. X     */
  1011. X
  1012. X    bytetimeout = byteto;
  1013. X    Iot0.tr_time.tv_secs = 3;
  1014. X    Iot0.tr_time.tv_micro= 0;
  1015. X    SendIO(&Iot0);
  1016. X
  1017. X    Iosr.IOSer.io_Command = CMD_READ;
  1018. X    Iosr.IOSer.io_Data = (APTR)XInBuf;
  1019. X    Iosr.IOSer.io_Length = 1;
  1020. X    Iosr.IOSer.io_Actual = 0;    /*  trying to find a bug... */
  1021. X    SendIO(&Iosr);
  1022. X
  1023. X    smask = 1L << Iosr.IOSer.io_Message.mn_ReplyPort->mp_SigBit;
  1024. X    tmask = 1L << Iot0.tr_node.io_Message.mn_ReplyPort->mp_SigBit;
  1025. X
  1026. X    for (;;) {
  1027. X    long mask = Wait(tmask | smask | SIGBREAKF_CTRL_C);
  1028. X
  1029. X    if (mask & SIGBREAKF_CTRL_C) {
  1030. X        AbortIO(&Iosr);
  1031. X        WaitIO(&Iosr);
  1032. X        AbortIO(&Iot0);
  1033. X        WaitIO(&Iot0);
  1034. X        xexit(1);
  1035. X    }
  1036. X    if (CheckIO(&Iosr)) {
  1037. X        WaitIO(&Iosr);
  1038. X        AbortIO(&Iot0);
  1039. X        WaitIO(&Iot0);
  1040. X
  1041. X        ch = (int)XInBuf[0];
  1042. X
  1043. X        if (debug > 8) {
  1044. X        if (debugRead == 0)
  1045. X            printf("\nREAD ");
  1046. X        debugRead = 1;
  1047. X        printf("(waitc%d)", Iosr.IOSer.io_Actual);
  1048. X        printc(ch);
  1049. X        }
  1050. X        return(ch);
  1051. X    }
  1052. X    if (CheckIO(&Iot0)) {
  1053. X        WaitIO(&Iot0);
  1054. X
  1055. X        Iot0.tr_time.tv_secs = 3;
  1056. X        Iot0.tr_time.tv_micro= 0;
  1057. X
  1058. X        bytetimeout -= Iot0.tr_time.tv_secs;
  1059. X        if (bytetimeout > 0) {
  1060. X        if (CheckCarrier() == 0) {
  1061. X            AbortIO(&Iosr);
  1062. X            WaitIO(&Iosr);
  1063. X            break;
  1064. X        }
  1065. X        SendIO(&Iot0);
  1066. X        } else {
  1067. X        AbortIO(&Iosr);
  1068. X        WaitIO(&Iosr);
  1069. X        if (Iosr.IOSer.io_Actual == 1)
  1070. X            return((int)XInBuf[0]);
  1071. X        break;
  1072. X        }
  1073. X    }
  1074. X    }
  1075. X    if (debug > 8)
  1076. X    printf("\nRecv-EOF\n");
  1077. X    return(EOF);
  1078. X}
  1079. X
  1080. Xxwrite(buf, ctr)
  1081. Xunsigned char *buf;
  1082. Xint ctr;
  1083. X{
  1084. X    return(xxwrite(buf, ctr, 0));
  1085. X}
  1086. X
  1087. Xxwritea(buf, ctr)
  1088. Xunsigned char *buf;
  1089. Xint ctr;
  1090. X{
  1091. X    xxwrite(buf, ctr, 1);
  1092. X    return(ctr);
  1093. X}
  1094. X
  1095. Xxxwrite(buf, ctr, async)
  1096. Xunsigned char *buf;
  1097. Xint ctr;
  1098. X{
  1099. X    if (debug > 8) {
  1100. X    short i;
  1101. X    if (debugRead)
  1102. X        printf("\nWRITE ");
  1103. X    debugRead = 0;
  1104. X    for (i = 0; i < ctr; ++i) {
  1105. X        printc(buf[i]);
  1106. X    }
  1107. X    printf("\n");
  1108. X    }
  1109. X    if (IoswIP) {
  1110. X    WaitIO(&Iosw);
  1111. X    IoswIP = 0;
  1112. X    }
  1113. X
  1114. X    Iosw.IOSer.io_Command = CMD_WRITE;
  1115. X    Iosw.IOSer.io_Length = ctr;
  1116. X    Iosw.IOSer.io_Data = (APTR) &buf[0];
  1117. X    if (async) {
  1118. X    SendIO(&Iosw);
  1119. X    IoswIP = 1;
  1120. X    } else {
  1121. X    DoIO(&Iosw);
  1122. X    }
  1123. X    return ctr;
  1124. X}
  1125. X
  1126. Xvoid
  1127. XSendBreak()
  1128. X{
  1129. X    Ioss.IOSer.io_Command = SDCMD_BREAK;
  1130. X    DoIO(&Ioss);
  1131. X}
  1132. X
  1133. XCheckCarrier()
  1134. X{
  1135. X    Ioss.IOSer.io_Command = SDCMD_QUERY;
  1136. X    DoIO(&Ioss);
  1137. X    if (IgnoreCD)
  1138. X    return(1);
  1139. X    if (Ioss.io_Status & CIAF_COMCD)    /*  non-zero == no carrier */
  1140. X    return(0);
  1141. X    return(1);
  1142. X}
  1143. X
  1144. Xvoid
  1145. Xbzero(s, cnt)
  1146. Xchar   *s;
  1147. Xint    cnt;
  1148. X{
  1149. X    int    i;
  1150. X    for (i = 0; i < cnt; i++) {
  1151. X    *s++ = '\0';
  1152. X    }
  1153. X}
  1154. X
  1155. Xvoid
  1156. Xbcopy(from, to, cnt)
  1157. Xchar   *from;
  1158. Xchar   *to;
  1159. Xint    cnt;
  1160. X{
  1161. X    int    i;
  1162. X    for (i = 0; i < cnt; i++) {
  1163. X    *to++ = *from++;
  1164. X    }
  1165. X}
  1166. X
  1167. X/*
  1168. X * Transform a filename from a uucp packet (in Unix format) into a local
  1169. X * filename that will work in the local file system.
  1170. X */
  1171. X
  1172. Xvoid
  1173. Xmunge_filename(s, d)
  1174. Xchar *s, *d;
  1175. X{
  1176. X    if (*s != '~') {
  1177. X    if (s != d)
  1178. X        strcpy(d, s);
  1179. X    return;
  1180. X    }
  1181. X
  1182. X    /*
  1183. X     *    ~/ ...    convert to UUPUB:
  1184. X     *    ~user/...   convert to <homedir>/...
  1185. X     */
  1186. X
  1187. X    {
  1188. X    short i;
  1189. X    short c;
  1190. X    char *t;
  1191. X    struct passwd *pw;
  1192. X
  1193. X    for (i = 1; s[i] && s[i] != '/'; ++i);
  1194. X    c = s[i];
  1195. X
  1196. X    s[i] = 0;
  1197. X    if (i == 1)
  1198. X        pw = NULL;
  1199. X    else
  1200. X        pw = getpwnam(s + 1);
  1201. X    s[i] = c;
  1202. X
  1203. X    if (c == '/')
  1204. X        ++i;
  1205. X
  1206. X    if (pw) {
  1207. X        t = malloc(strlen(pw->pw_dir) + strlen(s + i) + 1);
  1208. X        strcpy(t, pw->pw_dir);
  1209. X    } else {
  1210. X        t = malloc(strlen(s + i) + 32);
  1211. X        strcpy(t, "UUPUB:");
  1212. X    }
  1213. X    strcat(t, s + i);
  1214. X    strcpy(d, t);
  1215. X    free(t);
  1216. X    }
  1217. X}
  1218. X
  1219. Xhangup()
  1220. X{
  1221. X    reset_modem();
  1222. X
  1223. X    if (Execute("run >nil: <nil: uuxqt", NULL, NULL) == 0) {
  1224. X    if (Execute("run >nil: <nil: uucp:c/uuxqt", NULL, NULL) == 0)
  1225. X        puts("Unable to run UUXQT");
  1226. X    }
  1227. X    return SUCCESS;
  1228. X}
  1229. X
  1230. Xstatic char names[3000];
  1231. Xstatic char *pointers[300];
  1232. Xstatic int file_pointer;
  1233. X
  1234. Xchar *
  1235. Xwork_scan(system_name)
  1236. Xchar *system_name;
  1237. X{
  1238. X    static char name[128];
  1239. X    int count;
  1240. X
  1241. X    file_pointer = 0;
  1242. X
  1243. X    if (strlen(system_name) > 7) {
  1244. X    system_name[7] = '\0';
  1245. X    }
  1246. X
  1247. X    sprintf(name,"UUSPOOL:C.%s#?", system_name);
  1248. X
  1249. X    if (debug > 2)
  1250. X    printf("Looking for %s\n",name);
  1251. X
  1252. X    count = getfnl(name,names,sizeof(names),0);
  1253. X
  1254. X    if (count > 0) {
  1255. X    if (strbpl(pointers,300,names) != count) {
  1256. X        printf("Too many command files for %s.\n",system_name);
  1257. X        return (char *)NULL;
  1258. X    }
  1259. X    } else {
  1260. X    return (char *)NULL;
  1261. X    }
  1262. X    if (debug > 2)
  1263. X    printf("Found -> %s\n", pointers[file_pointer]);
  1264. X    return (char *)1;
  1265. X}
  1266. X
  1267. Xchar *
  1268. Xwork_next(system_name)
  1269. Xchar *system_name;
  1270. X{
  1271. X    if (debug > 2)
  1272. X    printf("Found -> %s\n", pointers[file_pointer]);
  1273. X    return pointers[file_pointer++];
  1274. X}
  1275. X
  1276. X/*
  1277. X *  Closing and openning the serial device drops DTR
  1278. X */
  1279. X
  1280. Xvoid
  1281. Xamiga_closeopen(str)
  1282. Xchar *str;
  1283. X{
  1284. X    CloseSerial();
  1285. X    Delay(60);
  1286. X    OpenSerial();
  1287. X}
  1288. X
  1289. Xvoid
  1290. Xamiga_setup()
  1291. X{
  1292. X    mountrequest(0);        /*  disallow requesters */
  1293. X
  1294. X    OpenSerial();
  1295. X
  1296. X    if (OpenDevice(TIMERNAME, UNIT_VBLANK, &Iot0, 0))  {
  1297. X    Iot0.tr_node.io_Device = NULL;
  1298. X    printf("Can't open timer device.");
  1299. X    xexit(1);
  1300. X    }
  1301. X
  1302. X    Iot0.tr_node.io_Message.mn_ReplyPort = CreatePort("UUCICO-Timer", 0L);
  1303. X    Iot0.tr_node.io_Command = TR_ADDREQUEST;
  1304. X    Iot0.tr_node.io_Error = 0;
  1305. X
  1306. X    {
  1307. X    struct Task *task = (struct Task *)FindTask(NULL);
  1308. X    OldTaskName = task->tc_Node.ln_Name;
  1309. X    task->tc_Node.ln_Name = "uucico";
  1310. X    }
  1311. X}
  1312. X
  1313. Xvoid
  1314. Xset_baud(baud)
  1315. Xint baud;
  1316. X{
  1317. X    Iosr.IOSer.io_Command = SDCMD_SETPARAMS;
  1318. X    Iosr.io_SerFlags =    SERF_SHARED | SERF_XDISABLED;
  1319. X    Iosr.io_Baud = baud;
  1320. X    Iosr.io_ReadLen = 8L;
  1321. X    Iosr.io_WriteLen = 8L;
  1322. X    Iosr.io_CtlChar = 0x11130000L;
  1323. X    Iosr.io_RBufLen = 4096;
  1324. X
  1325. X    DoIO(&Iosr);
  1326. X}
  1327. X
  1328. Xvoid
  1329. XOpenSerial()
  1330. X{
  1331. X    Iosr.io_SerFlags = SERF_SHARED | SERF_XDISABLED;
  1332. X    Iosr.IOSer.io_Message.mn_ReplyPort = CreatePort("Read_RS",0);
  1333. X
  1334. X    if (OpenDevice(DeviceName, DeviceUnit, &Iosr, NULL)) {
  1335. X    Iosr.IOSer.io_Device = NULL;
  1336. X    printf("Can not open serial port for read.\n");
  1337. X    xexit(TRUE);
  1338. X    }
  1339. X
  1340. X    /*
  1341. X     *    Assume a Getty is running, if the opencount is > 2 then
  1342. X     *    assume collision and disallow
  1343. X     */
  1344. X
  1345. X    if (Iosr.IOSer.io_Device->dd_Library.lib_OpenCnt > 2) {
  1346. X    CloseDevice(&Iosr);
  1347. X    Iosr.IOSer.io_Device = NULL;
  1348. X    printf("Collision, serial port in use!\n");
  1349. X    xexit(TRUE);
  1350. X    }
  1351. X
  1352. X    /*
  1353. X     *    The public port 'Lock-<spname>-<unit>' is used to lock the
  1354. X     *    serial port (Getty will lock it this way while it is
  1355. X     *    receiving an incomming call so if we are Getty assume it
  1356. X     *    is already locked)
  1357. X     */
  1358. X
  1359. X    if (Getty == 0)
  1360. X    LockSerialPort(DeviceName, DeviceUnit);
  1361. X
  1362. X    Iosw = Iosr;
  1363. X    Iosw.IOSer.io_Message.mn_ReplyPort = CreatePort("Write_RS", 0);
  1364. X    Ioss = Iosw;
  1365. X
  1366. X    Iosr.IOSer.io_Command = SDCMD_QUERY;
  1367. X    DoIO(&Iosr);
  1368. X
  1369. X    set_baud(Iosr.io_Baud);
  1370. X}
  1371. X
  1372. Xvoid
  1373. XCloseSerial()
  1374. X{
  1375. X    if (IoswIP) {
  1376. X    WaitIO(&Iosw);
  1377. X    IoswIP = 0;
  1378. X    }
  1379. X    if (Iosr.IOSer.io_Device) {
  1380. X    CloseDevice(&Iosr);
  1381. X    Iosr.IOSer.io_Device = NULL;
  1382. X    if (Getty == 0)
  1383. X        UnLockSerialPort(DeviceName, DeviceUnit);
  1384. X    }
  1385. X    if (Iosr.IOSer.io_Message.mn_ReplyPort) {
  1386. X    DeletePort(Iosr.IOSer.io_Message.mn_ReplyPort);
  1387. X    Iosr.IOSer.io_Message.mn_ReplyPort = NULL;
  1388. X    }
  1389. X    if (Iosw.IOSer.io_Message.mn_ReplyPort) {
  1390. X    DeletePort(Iosw.IOSer.io_Message.mn_ReplyPort);
  1391. X    Iosw.IOSer.io_Message.mn_ReplyPort = NULL;
  1392. X    }
  1393. X}
  1394. X
  1395. Xvoid
  1396. Xxexit(code)
  1397. X{
  1398. X    ++InExitRoutine;
  1399. X
  1400. X    if (InExitRoutine == 1 && code && Iosr.IOSer.io_Device && CheckCarrier())
  1401. X    reset_modem();
  1402. X
  1403. X    CloseSerial();
  1404. X
  1405. X    {
  1406. X    struct Task *task = (struct Task *)FindTask(NULL);
  1407. X    if (OldTaskName)
  1408. X        task->tc_Node.ln_Name = OldTaskName;
  1409. X    }
  1410. X
  1411. X    if (Iot0.tr_node.io_Device) {
  1412. X    CloseDevice(&Iot0);
  1413. X    Iot0.tr_node.io_Device = NULL;
  1414. X    }
  1415. X    if (Iot0.tr_node.io_Message.mn_ReplyPort) {
  1416. X    DeletePort(Iot0.tr_node.io_Message.mn_ReplyPort);
  1417. X    Iot0.tr_node.io_Message.mn_ReplyPort = NULL;
  1418. X    }
  1419. X    chdir(path);
  1420. X    if (code)
  1421. X    printf("\nAbnormal Termination.\n");
  1422. X
  1423. X    mountrequest(1);
  1424. X
  1425. X    UnLockFiles();      /*  unlock any hanging locks */
  1426. X
  1427. X    exit(code);
  1428. X}
  1429. X
  1430. Xvoid
  1431. Xprintc(c)
  1432. Xunsigned char c;
  1433. X{
  1434. X    c &= 0x7F;
  1435. X
  1436. X    if (c < 32)
  1437. X    printf("^%c", c | 0x40);
  1438. X    else if (c == 32)
  1439. X    printf("_");
  1440. X    else if (c < 128)
  1441. X    printf("%c", c);
  1442. X    else
  1443. X    printf("(%02x)", c);
  1444. X}
  1445. X
  1446. END_OF_FILE
  1447. if test 11298 -ne `wc -c <'src/uucico/sysdep.c'`; then
  1448.     echo shar: \"'src/uucico/sysdep.c'\" unpacked with wrong size!
  1449. fi
  1450. # end of 'src/uucico/sysdep.c'
  1451. fi
  1452. if test -f 'src/uuser/uuser.c' -a "${1}" != "-c" ; then 
  1453.   echo shar: Will not clobber existing file \"'src/uuser/uuser.c'\"
  1454. else
  1455. echo shar: Extracting \"'src/uuser/uuser.c'\" \(13243 characters\)
  1456. sed "s/^X//" >'src/uuser/uuser.c' <<'END_OF_FILE'
  1457. X
  1458. X/*
  1459. X *  UUSER.C UUSER:devicename/unitnumber/options
  1460. X *        UUSER:serial.device/0/R1000
  1461. X *
  1462. X *  (C) Copyright 1989-1990 by Matthew Dillon,  All Rights Reserved.
  1463. X *
  1464. X *  options:
  1465. X *    Rn    Set read timeout when no data available to n millisecs
  1466. X *    C0    Ignore carrier detect
  1467. X *
  1468. X *  features:
  1469. X *    1K asynchronous write capability (write 0 bytes to sync up)
  1470. X *    programmable read-timeout (Getty starts procs up w/ 1sec to)
  1471. X *
  1472. X *    combined together, you can easily implement 100% efficient
  1473. X *    protocols even with that 1 second read timeout!
  1474. X */
  1475. X
  1476. X#include <exec/types.h>
  1477. X#include <exec/memory.h>
  1478. X#include <devices/serial.h>
  1479. X#include <devices/timer.h>
  1480. X#include <libraries/dos.h>
  1481. X#include <libraries/dosextens.h>
  1482. X#include <libraries/filehandler.h>
  1483. X#include <hardware/cia.h>
  1484. X#include <proto/all.h>
  1485. X
  1486. X#define WRITEBUFSIZE    1024
  1487. X#define MPC (MEMF_PUBLIC|MEMF_CLEAR)        /* options to AllocMem()    */
  1488. X
  1489. X#define BTOC(x, type)   ((type *)((long)x << 2))
  1490. X#define CTOB(x)         ((BPTR)((long)x >> 2))
  1491. X
  1492. X#define DOS_FALSE    0
  1493. X#define DOS_TRUE     -1
  1494. X
  1495. Xtypedef struct IOExtSer     IOS;
  1496. Xtypedef struct timerequest  IOT;
  1497. Xtypedef struct IORequest    IOR;
  1498. Xtypedef struct timeval        TimeVal;
  1499. X
  1500. Xtypedef struct FileLock     LOCK;
  1501. Xtypedef struct DosPacket    Packet;
  1502. Xtypedef struct Process        PROC;
  1503. Xtypedef struct DeviceNode   DEVNODE;
  1504. Xtypedef struct FileHandle   FH;
  1505. Xtypedef struct Message        MSG;
  1506. Xtypedef struct Node        NODE;
  1507. Xtypedef struct List        LIST;
  1508. Xtypedef struct MsgPort        PORT;
  1509. X
  1510. Xtypedef struct SHandle {
  1511. X    NODE    Node;
  1512. X    IOT     Iot;        /* wait-for-char and read req    */
  1513. X    IOS     Ios;
  1514. X    IOS     Iosr;        /* 1005             */
  1515. X    IOS     Iosw;        /* 1005,1006            */
  1516. X    char    IotIP;
  1517. X    char    IosrIP;
  1518. X    char    IoswIP;
  1519. X    char    RxIn[1];        /* one char buffer        */
  1520. X    char    *TxOut;        /* asynch write buffer        */
  1521. X    Packet  *RPacket;        /* current pending read packet    */
  1522. X    Packet  *WPacket;        /* current pending write packet */
  1523. X    short   Flags;
  1524. X    LIST    RxWait;        /* requests waiting for data    */
  1525. X    LIST    TxWait;        /* requests waiting to write    */
  1526. X    LIST    CxWait;        /* wait for char        */
  1527. X    TimeVal ReadTo;
  1528. X} SHandle;
  1529. X
  1530. X#define HF_IGNORECD    0x01
  1531. X#define HF_CDLOST    0x02
  1532. X#define HF_RTO        0x04
  1533. X#define HF_DONTLOCK    0x08    /* if G option for from-getty    */
  1534. X
  1535. Xextern Packet *taskwait();   /* wait for a message           */
  1536. X
  1537. Xlong SysBase;            /* required to make Exec calls    */
  1538. Xchar ScrBuf[256];        /* Scratch buffer        */
  1539. XPORT *IoSink;
  1540. XLIST HanList;
  1541. XLIST NodList;
  1542. XIOT  Iot;            /* Iot master, also used for CD */
  1543. Xchar IotIP;
  1544. X
  1545. Xvoid    AttemptRead();
  1546. Xvoid    AttemptWrite();
  1547. Xvoid    AbortPackets();
  1548. Xvoid    StartTimer();
  1549. X
  1550. X__saveds void
  1551. X_dummy()
  1552. X{
  1553. X    PROC    *myproc;
  1554. X    DEVNODE    *mynode;
  1555. X    UBYTE    notdone;
  1556. X    long    mask;
  1557. X
  1558. X    SysBase = *(long *)4;
  1559. X    IoSink = CreatePort(NULL, 0);
  1560. X    NewList(&HanList);
  1561. X    NewList(&NodList);
  1562. X
  1563. X    Iot.tr_node.io_Message.mn_ReplyPort = IoSink;
  1564. X    OpenDevice("timer.device", UNIT_VBLANK, &Iot, 0);
  1565. X    Iot.tr_node.io_Command = TR_ADDREQUEST;
  1566. X    Iot.tr_time.tv_secs = 4;
  1567. X    Iot.tr_time.tv_micro= 0;
  1568. X    SendIO(&Iot);
  1569. X    IotIP = 1;
  1570. X
  1571. X    myproc  = (PROC *)FindTask(0L);
  1572. X
  1573. X    /*
  1574. X     * INITIAL STARTUP MESSAGE
  1575. X     */
  1576. X
  1577. X    {
  1578. X    Packet *mypkt;
  1579. X
  1580. X    mypkt    = taskwait(myproc);
  1581. X    mynode    = BTOC(mypkt->dp_Arg3, DEVNODE);
  1582. X    mynode->dn_Task = &myproc->pr_MsgPort;
  1583. X    returnpkt(mypkt, myproc, DOS_TRUE, 0);
  1584. X    }
  1585. X
  1586. Xloop:
  1587. X    notdone = 1;
  1588. X    mask = (1 << IoSink->mp_SigBit) | (1 << myproc->pr_MsgPort.mp_SigBit);
  1589. X    while (notdone) {
  1590. X    Packet *mypkt;         /* dos packet received      */
  1591. X    IOR *ior;
  1592. X    SHandle *handle;
  1593. X    long type;            /* type of packet        */
  1594. X
  1595. X    ior = (IOR *)GetMsg(IoSink);
  1596. X    mypkt = (Packet *)GetMsg(&myproc->pr_MsgPort);
  1597. X    if (mypkt)
  1598. X        mypkt = (Packet *)(((MSG *)mypkt)->mn_Node.ln_Name);
  1599. X    while (mypkt == NULL && ior == NULL) {
  1600. X        Wait(mask);
  1601. X        ior = (IOR *)GetMsg(IoSink);
  1602. X        mypkt = (Packet *)GetMsg(&myproc->pr_MsgPort);
  1603. X        if (mypkt)
  1604. X        mypkt = (Packet *)(((MSG *)mypkt)->mn_Node.ln_Name);
  1605. X    }
  1606. X
  1607. X    /*
  1608. X     *  Make sure there is at least one free node in node list
  1609. X     */
  1610. X
  1611. X    if (NodList.lh_Head == (NODE *)&NodList.lh_Tail) {
  1612. X        NODE *pknode = AllocMem(sizeof(NODE), MPC);
  1613. X        AddTail(&NodList, pknode);
  1614. X    }
  1615. X
  1616. X    /*
  1617. X     *  Returned IO request, sift through lists to find it.
  1618. X     */
  1619. X
  1620. X    if (ior) {
  1621. X        if (ior == &Iot) {      /*  Check for carrier lost */
  1622. X        for (handle = (SHandle *)HanList.lh_Head; handle != (SHandle *)&HanList.lh_Tail; handle = (SHandle *)handle->Node.ln_Succ) {
  1623. X            if (!(handle->Flags & HF_IGNORECD) && !(handle->Flags & HF_CDLOST)) {
  1624. X            handle->Ios.IOSer.io_Command = SDCMD_QUERY;
  1625. X            DoIO(&handle->Ios);
  1626. X            if (handle->Ios.io_Status & CIAF_COMCD) {
  1627. X                handle->Flags |= HF_CDLOST;
  1628. X                AbortPackets(handle, myproc);
  1629. X            }
  1630. X            }
  1631. X        }
  1632. X        if (HanList.lh_Head == (NODE *)&HanList.lh_Tail) {
  1633. X            IotIP = 0;
  1634. X        } else {
  1635. X            Iot.tr_time.tv_secs = 4;
  1636. X            Iot.tr_time.tv_micro= 0;
  1637. X            SendIO(&Iot);
  1638. X            IotIP = 1;
  1639. X        }
  1640. X        } else
  1641. X        for (handle = (SHandle *)HanList.lh_Head; handle != (SHandle *)&HanList.lh_Tail; handle = (SHandle *)handle->Node.ln_Succ) {
  1642. X        if (ior == (IOR *)&handle->Iosr) {
  1643. X            returnpkt(handle->RPacket, myproc, handle->Iosr.IOSer.io_Actual, 0);
  1644. X            handle->IosrIP = 0;
  1645. X            handle->RPacket = NULL;
  1646. X
  1647. X            if (handle->IotIP) {
  1648. X            AbortIO(&handle->Iot);
  1649. X            WaitIO(&handle->Iot);
  1650. X            handle->IotIP = 0;
  1651. X            }
  1652. X            AttemptRead(handle, myproc);
  1653. X        }
  1654. X        if (ior == (IOR *)&handle->Iosw) {
  1655. X            handle->IoswIP = 0;
  1656. X            if (handle->WPacket) {
  1657. X            handle->Iosw.IOSer.io_Data = (APTR)handle->TxOut;
  1658. X            handle->Iosw.IOSer.io_Length= handle->WPacket->dp_Arg3 - handle->WPacket->dp_Res1;
  1659. X            SendIO(&handle->Iosw);
  1660. X            handle->IoswIP = 1;
  1661. X            handle->WPacket->dp_Res1 = handle->WPacket->dp_Arg3;
  1662. X            returnpktplain(handle->WPacket, myproc);
  1663. X            handle->WPacket = NULL;
  1664. X            } else {
  1665. X            AttemptWrite(handle, myproc);
  1666. X            }
  1667. X        }
  1668. X        if (ior == (IOR *)&handle->Iot) {
  1669. X            handle->IotIP = 0;
  1670. X            if ((handle->Flags & HF_RTO) && handle->IosrIP) {
  1671. X            AbortIO(&handle->Iosr);
  1672. X            }
  1673. X        }
  1674. X        }
  1675. X    }
  1676. X
  1677. X    if (mypkt) {
  1678. X        mypkt->dp_Res1 = DOS_TRUE;    /* default return value     */
  1679. X        mypkt->dp_Res2 = 0;     /* default no error        */
  1680. X        type = mypkt->dp_Type;    /* packet type            */
  1681. X
  1682. X        /*
  1683. X         *    Extract pipe pointer (only applies to read/write)
  1684. X         */
  1685. X
  1686. X        handle = (SHandle *)mypkt->dp_Arg1;     /*  READ/WRITE only */
  1687. X
  1688. X        switch(type) {
  1689. X        case ACTION_FINDINPUT:
  1690. X        case ACTION_FINDOUTPUT:
  1691. X        case ACTION_FINDUPDATE:
  1692. X        if (IotIP == 0)
  1693. X            StartTimer(4);
  1694. X        {
  1695. X            FH     *fh = BTOC(mypkt->dp_Arg1, FH);
  1696. X            char *path = BTOC(mypkt->dp_Arg3, char);
  1697. X            char *unit;
  1698. X            long n;
  1699. X
  1700. X            movmem(path + 1, ScrBuf, *path);
  1701. X            ScrBuf[*path] = 0;
  1702. X            path = ScrBuf;
  1703. X
  1704. X            handle = AllocMem(sizeof(SHandle), MPC);
  1705. X
  1706. X            if (strcmp(ScrBuf, "*") == 0)
  1707. X            strcpy(ScrBuf, "serial.device/0");
  1708. X            for (unit = path; *unit && *unit != '/'; ++unit) {
  1709. X            if (*unit == ':')
  1710. X                path = unit + 1;
  1711. X            }
  1712. X            if (*unit == '/') {
  1713. X            char *opts;
  1714. X
  1715. X            *unit = 0;
  1716. X            ++unit;
  1717. X            for (opts = unit; *opts && *opts != '/'; ++opts);
  1718. X            while (*opts) {
  1719. X                n = atoi(opts + 1);
  1720. X                switch(*opts) {
  1721. X                case '/':
  1722. X                break;
  1723. X                case 'R':
  1724. X                handle->ReadTo.tv_secs = n / 1000;
  1725. X                handle->ReadTo.tv_micro= (n % 1000) * 1000;
  1726. X                handle->Flags |= HF_RTO;
  1727. X                break;
  1728. X                case 'C':
  1729. X                handle->Flags |= HF_IGNORECD;
  1730. X                break;
  1731. X                case 'G':
  1732. X                if (n)
  1733. X                    handle->Flags |= HF_DONTLOCK;
  1734. X                break;
  1735. X                }
  1736. X                ++opts;
  1737. X            }
  1738. X            }
  1739. X
  1740. X            /* proc = (PROC *)mypkt->dp_Port->mp_SigTask; */
  1741. X
  1742. X            /*
  1743. X             * Open the device
  1744. X             */
  1745. X
  1746. X            handle->Ios.IOSer.io_Message.mn_ReplyPort = IoSink;
  1747. X            handle->Ios.io_SerFlags = SERF_XDISABLED | SERF_RAD_BOOGIE | SERF_SHARED;
  1748. X            if (OpenDevice(path, atoi(unit), &handle->Ios, 0)) {
  1749. X            FreeMem(handle, sizeof(SHandle));
  1750. X            mypkt->dp_Res1 = DOS_FALSE;
  1751. X            mypkt->dp_Res2 = ERROR_OBJECT_NOT_FOUND;
  1752. X            returnpktplain(mypkt, myproc);
  1753. X            break;
  1754. X            }
  1755. X            fh->fh_Arg1 = (long)handle;
  1756. X            fh->fh_Port = (struct MsgPort *)DOS_TRUE;
  1757. X
  1758. X            handle->Iosr = handle->Ios;
  1759. X            handle->Iosw = handle->Ios;
  1760. X            handle->Iosr.IOSer.io_Command = CMD_READ;
  1761. X            handle->Iosw.IOSer.io_Command = CMD_WRITE;
  1762. X            handle->Iot = Iot;
  1763. X            NewList(&handle->RxWait);
  1764. X            NewList(&handle->TxWait);
  1765. X            NewList(&handle->CxWait);
  1766. X            AddTail(&HanList, handle);
  1767. X            returnpktplain(mypkt, myproc);
  1768. X        }
  1769. X        break;
  1770. X        case ACTION_END:
  1771. X        Remove(handle);
  1772. X        if (handle->IosrIP) {
  1773. X            AbortIO(&handle->Iosr);
  1774. X            WaitIO(&handle->Iosr);
  1775. X        }
  1776. X        if (handle->IoswIP) {
  1777. X            WaitIO(&handle->Iosw);
  1778. X        }
  1779. X        if (handle->IotIP) {
  1780. X            AbortIO(&handle->Iot);
  1781. X            WaitIO(&handle->Iot);
  1782. X        }
  1783. X        AbortPackets(handle, myproc);
  1784. X        CloseDevice(&handle->Ios);
  1785. X        returnpktplain(mypkt, myproc);
  1786. X        if (handle->TxOut)
  1787. X            FreeMem(handle->TxOut, WRITEBUFSIZE);
  1788. X        FreeMem(handle, sizeof(SHandle));
  1789. X        break;
  1790. X        case ACTION_READ:
  1791. X        {
  1792. X            NODE *pknode = RemHead(&NodList);
  1793. X            mypkt->dp_Res1 = 0;
  1794. X            pknode->ln_Name = (char *)mypkt;
  1795. X            AddTail(&handle->RxWait, pknode);
  1796. X            AttemptRead(handle, myproc);
  1797. X        }
  1798. X        break;
  1799. X        case ACTION_WRITE:
  1800. X        {
  1801. X            NODE *pknode = RemHead(&NodList);
  1802. X            mypkt->dp_Res1 = 0;
  1803. X            pknode->ln_Name = (char *)mypkt;
  1804. X            AddTail(&handle->TxWait, pknode);
  1805. X            AttemptWrite(handle, myproc);
  1806. X        }
  1807. X        break;
  1808. X        case ACTION_WAIT_CHAR:
  1809. X        default:
  1810. X        returnpkt(mypkt, myproc, DOS_FALSE, ERROR_ACTION_NOT_KNOWN);
  1811. X        break;
  1812. X        }
  1813. X    }
  1814. X    }
  1815. X
  1816. X    /*
  1817. X     *    Can only exit if no messages pending.  There might be a window
  1818. X     *    here, but there is nothing that can be done about it.
  1819. X     */
  1820. X
  1821. X    Forbid();
  1822. X    if (taskpktrdy(myproc)) {
  1823. X    Permit();
  1824. X    goto loop;
  1825. X    }
  1826. X    mynode->dn_Task = FALSE;
  1827. X    Permit();
  1828. X
  1829. X    if (IotIP) {
  1830. X    AbortIO(&Iot);
  1831. X    WaitIO(&Iot);
  1832. X    }
  1833. X    CloseDevice(&Iot);
  1834. X
  1835. X    /* we are a process "so we fall off the end of the world" */
  1836. X    /* MUST fall through */
  1837. X}
  1838. X
  1839. Xvoid
  1840. XAttemptRead(handle, myproc)
  1841. XSHandle *handle;
  1842. XPROC *myproc;
  1843. X{
  1844. X    Packet *mypkt;
  1845. X    NODE *pknode;
  1846. X
  1847. X    if (handle->Flags & HF_CDLOST) {
  1848. X    AbortPackets(handle, myproc);
  1849. X    return;
  1850. X    }
  1851. Xloop:
  1852. X    if (handle->IosrIP == 0 && (pknode = RemHead(&handle->RxWait))) {
  1853. X    long n;
  1854. X
  1855. X    AddTail(&NodList, pknode);
  1856. X
  1857. X    mypkt = (Packet *)pknode->ln_Name;
  1858. X
  1859. X    /*
  1860. X     *  special case.  If you read 0 bytes, 0 is returned if data
  1861. X     *  is pending, else -1, and NO timeout occurs.
  1862. X     */
  1863. X
  1864. X    handle->Ios.IOSer.io_Command = SDCMD_QUERY;
  1865. X    DoIO(&handle->Ios);
  1866. X
  1867. X    if (mypkt->dp_Arg3 == 0) {
  1868. X        if (handle->Ios.IOSer.io_Actual > 0)
  1869. X        returnpkt(mypkt, myproc, 0, 0);     /* 0=data rdy */
  1870. X        else
  1871. X        returnpkt(mypkt, myproc, -1, 0);    /* -1=data not rdy */
  1872. X        goto loop;
  1873. X    }
  1874. X
  1875. X    if ((n = handle->Ios.IOSer.io_Actual) > 0) {
  1876. X        if (n > mypkt->dp_Arg3)
  1877. X        n = mypkt->dp_Arg3;
  1878. X        handle->Iosr.IOSer.io_Data = (APTR)mypkt->dp_Arg2;
  1879. X        handle->Iosr.IOSer.io_Length = n;
  1880. X        DoIO(&handle->Iosr);
  1881. X        mypkt->dp_Res1 = handle->Iosr.IOSer.io_Actual;
  1882. X        returnpktplain(mypkt, myproc);
  1883. X        goto loop;
  1884. X    }
  1885. X    handle->Iosr.IOSer.io_Data = (APTR)mypkt->dp_Arg2;
  1886. X    handle->Iosr.IOSer.io_Length = 1;
  1887. X    SendIO(&handle->Iosr);
  1888. X    handle->IosrIP = 1;
  1889. X    handle->RPacket = mypkt;
  1890. X
  1891. X    if (handle->Flags & HF_RTO) {
  1892. X        if (handle->IotIP) {
  1893. X        AbortIO(&handle->Iot);
  1894. X        WaitIO(&handle->Iot);
  1895. X        }
  1896. X        handle->Iot.tr_time = handle->ReadTo;
  1897. X        SendIO(&handle->Iot);
  1898. X        handle->IotIP = 1;
  1899. X    }
  1900. X    }
  1901. X}
  1902. X
  1903. Xvoid
  1904. XAttemptWrite(handle, myproc)
  1905. XSHandle *handle;
  1906. XPROC *myproc;
  1907. X{
  1908. X    Packet *mypkt;
  1909. X    NODE *pknode;
  1910. X
  1911. X    if (handle->Flags & HF_CDLOST) {
  1912. X    AbortPackets(handle, myproc);
  1913. X    return;
  1914. X    }
  1915. X    if (handle->IoswIP == 0 && (pknode = RemHead(&handle->TxWait))) {
  1916. X    AddTail(&NodList, pknode);
  1917. X
  1918. X    mypkt = (Packet *)pknode->ln_Name;
  1919. X
  1920. X    if (handle->TxOut == NULL)
  1921. X        handle->TxOut = AllocMem(WRITEBUFSIZE, MPC);
  1922. X
  1923. X    if (mypkt->dp_Arg3 <= WRITEBUFSIZE) {   /* fully asynch */
  1924. X        movmem((char *)mypkt->dp_Arg2, handle->TxOut, mypkt->dp_Arg3);
  1925. X        handle->Iosw.IOSer.io_Data = (APTR)handle->TxOut;
  1926. X        handle->Iosw.IOSer.io_Length = mypkt->dp_Arg3;
  1927. X        SendIO(&handle->Iosw);
  1928. X        mypkt->dp_Res1 = mypkt->dp_Arg3;
  1929. X        returnpktplain(mypkt, myproc);
  1930. X        handle->WPacket = NULL;
  1931. X    } else {                /*  semi-asynch */
  1932. X        long n = mypkt->dp_Arg3 - WRITEBUFSIZE;
  1933. X        handle->Iosw.IOSer.io_Data = (APTR)mypkt->dp_Arg2;
  1934. X        handle->Iosw.IOSer.io_Length = n;
  1935. X        SendIO(&handle->Iosw);
  1936. X        movmem((char *)mypkt->dp_Arg2 + n, handle->TxOut, WRITEBUFSIZE);
  1937. X        mypkt->dp_Res1 += n;
  1938. X        handle->WPacket = mypkt;
  1939. X    }
  1940. X    handle->IoswIP = 1;
  1941. X    }
  1942. X}
  1943. X
  1944. Xvoid
  1945. XAbortPackets(handle, myproc)
  1946. XSHandle *handle;
  1947. X{
  1948. X    NODE *pknode;
  1949. X    Packet *mypkt;
  1950. X
  1951. X    if (handle->RPacket)
  1952. X    returnpktplain(handle->RPacket, myproc);
  1953. X    if (handle->WPacket)
  1954. X    returnpktplain(handle->RPacket, myproc);
  1955. X
  1956. X    handle->RPacket = NULL;
  1957. X    handle->WPacket = NULL;
  1958. X
  1959. X    while (pknode = RemHead(&handle->RxWait)) {
  1960. X    mypkt = (Packet *)pknode->ln_Name;
  1961. X    if (mypkt->dp_Arg3 == 0)
  1962. X        mypkt->dp_Res1 = 0;     /* for poll, return data rdy */
  1963. X    else
  1964. X        mypkt->dp_Res1 = -1;
  1965. X    returnpktplain(mypkt, myproc);
  1966. X    AddTail(&NodList, pknode);
  1967. X    }
  1968. X
  1969. X    while (pknode = RemHead(&handle->TxWait)) {
  1970. X    mypkt = (Packet *)pknode->ln_Name;
  1971. X    mypkt->dp_Res1 = -1;
  1972. X    returnpktplain(mypkt, myproc);
  1973. X    AddTail(&NodList, pknode);
  1974. X    }
  1975. X}
  1976. X
  1977. Xvoid
  1978. XStartTimer(secs)
  1979. X{
  1980. X    if (IotIP) {
  1981. X    AbortIO(&Iot);
  1982. X    WaitIO(&Iot);
  1983. X    }
  1984. X    Iot.tr_time.tv_secs = secs;
  1985. X    Iot.tr_time.tv_micro= 0;
  1986. X    SendIO(&Iot);
  1987. X    IotIP = 1;
  1988. X}
  1989. X
  1990. X
  1991. END_OF_FILE
  1992. if test 13243 -ne `wc -c <'src/uuser/uuser.c'`; then
  1993.     echo shar: \"'src/uuser/uuser.c'\" unpacked with wrong size!
  1994. fi
  1995. # end of 'src/uuser/uuser.c'
  1996. fi
  1997. echo shar: End of archive 7 \(of 16\).
  1998. cp /dev/null ark7isdone
  1999. MISSING=""
  2000. for I in 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 ; do
  2001.     if test ! -f ark${I}isdone ; then
  2002.     MISSING="${MISSING} ${I}"
  2003.     fi
  2004. done
  2005. if test "${MISSING}" = "" ; then
  2006.     echo You have unpacked all 16 archives.
  2007.     rm -f ark[1-9]isdone ark[1-9][0-9]isdone
  2008. else
  2009.     echo You still need to unpack the following archives:
  2010.     echo "        " ${MISSING}
  2011. fi
  2012. ##  End of shell archive.
  2013. exit 0
  2014. -- 
  2015. Submissions to comp.sources.amiga and comp.binaries.amiga should be sent to:
  2016.     amiga@cs.odu.edu    
  2017. or    amiga@xanth.cs.odu.edu    ( obsolescent mailers may need this address )
  2018. or    ...!uunet!xanth!amiga    ( very obsolescent mailers need this address )
  2019.  
  2020. Comments, questions, and suggestions should be addressed to ``amiga-request''
  2021. (please only use ``amiga'' for actual submissions) at the above addresses.
  2022.